//package com.talent.web.kafka;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.kafka.support.Acknowledgment;
//import org.springframework.stereotype.Service;
//
//import java.util.List;
//
///**
// * @ClassName：ConsumerService
// * @Author: hszhou
// * @Date: 2025/1/22 11:18
// * @Description: 必须描述类做什么事情, 实现什么功能
// */
//@Service
//public class ConsumerService {
//
//    protected  final Logger logger = LoggerFactory.getLogger(getClass());
//
//    @KafkaListener(topics = "web",containerFactory = "batchFactory")
//    public void processMessage(List<Object> message, Acknowledgment ack){
//        logger.info("收到kafka的主题web的消息{}",message);
//        ack.acknowledge();
//    }
//}
